﻿using Aquarinum.Base.Infrastructure.EventBus.Interfaces;

namespace Aquarinum.Base.Infrastructure.EventBus.Default
{
    /// <summary>
    /// 默认接收端错误处理方式
    /// <remarks>
    /// 默认处理逻辑为：根据消息类型名称把错误send回到对应错误队列，如果需要重试，则本地重试（是否是发还队列顶）处理到阈值再send到错误队列
    /// </remarks>
    /// </summary>
    public class DefaultConsumerErrorStrategy : IConsumerErrorStrategy
    {
        public string GetErrorQueueName()
        {
            throw new System.NotImplementedException();
        }

        public string GetErrorAbstract()
        {
            throw new System.NotImplementedException();
        }
    }
}